package cn.me.alphamq.broker.model.consumequeue;

/**
 * consumeQueue 文件消费的请求模型
 *
 * @author f
 */
public class ConsumeQueueConsumeReq {

    /**
     * 消费的主题名称
     */
    private String topic;

    /**
     * 消费者组的名称
     */
    private String consumerGroup;

    /**
     * 消费的队列 id
     */
    private Integer queueId;

    /**
     * 批量消费消息的数量
     */
    private Integer batchMsgNum;

    public ConsumeQueueConsumeReq(String topic, String consumerGroup, Integer queueId, Integer batchMsgNum) {
        this.topic = topic;
        this.consumerGroup = consumerGroup;
        this.queueId = queueId;
        this.batchMsgNum = batchMsgNum;
    }

    public String getTopic() {
        return topic;
    }

    public void setTopic(String topic) {
        this.topic = topic;
    }

    public String getConsumerGroup() {
        return consumerGroup;
    }

    public void setConsumerGroup(String consumerGroup) {
        this.consumerGroup = consumerGroup;
    }

    public Integer getQueueId() {
        return queueId;
    }

    public void setQueueId(Integer queueId) {
        this.queueId = queueId;
    }

    public Integer getBatchMsgNum() {
        return batchMsgNum;
    }

    public void setBatchMsgNum(Integer batchMsgNum) {
        this.batchMsgNum = batchMsgNum;
    }
}
